<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 山西牛酷信息科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com.cn
 * 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用。
 * 任何企业和个人不允许对程序代码以任何形式任何目的再发布。
 * =========================================================
 */

namespace app\pay\controller;


use app\Controller;
use app\model\web\WebSite;
use think\facade\Log;
use think\facade\Db;
/**
 * 支付控制器
 */
class Pay extends Controller
{
	public function connect(){
        $dbhost = '8.135.116.51';  // mysql服务器主机地址
        $dbuser = 'bby';            // mysql用户名
        $dbpass = 'i4GsmFCkJdmYH4xN';          // mysql用户名密码
        $dbname = 'bby';
        $conn = mysqli_connect($dbhost, $dbuser, $dbpass,$dbname);
        if(! $conn )
        {
            die('Could not connect: ' . mysqli_error());
        }
        // echo '数据库连接成功！';
        // 设置编码，防止中文乱码
        mysqli_query($conn , "set names utf8");

        return $conn;
    }
    public function getAll($conn,$sql){
        #执行查询操作
        $result  = $conn->query($sql);
        if(empty($result)){
            return '';
        }
        #定义返回接收数据的数组
        $data = array();
        #判断是否有数据
        if($result->num_rows){
            #循环把数据插入返回的数组中
            while($row = $result->fetch_assoc()){
                $data[] = $row;
            }
        }
        mysqli_free_result($result);
        #返回
        return $data;
    }

    public function test(){
        $orderinfo = Db::table('order o')->join('member m','o.member_id = m.member_id')->where('o.out_trade_no',16062929049330)->field('m.mobile,o.order_no')->find();
        halt($orderinfo);
        die;
        // $conn = $this->connect();
        // $cate_sql2 = 'update bby_puerpera_user SET first = 1 where mobile=18024173297';
      
        // $tuijian = $this->getAll($conn,$cate_sql2);
    }
	/**
	 * 支付异步回调
	 */
	public function notify()
	{
        $param = input();
//        Log::write('pay_notifiy_log:'.json_encode($param), 'notice');
	    event('PayNotify', []);
	}
	
	public function payReturn()
	{
        $app_type = input('app_type', '');
        $out_trade_no = input('out_trade_no', '');

        $website_model = new WebSite();
        $website_result = $website_model->getWebSite([['site_id', '=', 0]], 'wap_domain,web_domain');
        $website = $website_result['data'] ?? [];
        switch ($app_type){
            case 'pc':
                $return_url = $website['web_domain'].'/#/result?code='.$out_trade_no;
                $this->redirect($return_url);
                break;
            case 'h5':
                $return_url = $website['wap_domain'].'/pages/pay/result/result?code='.$out_trade_no;
                $this->redirect($return_url);
                break;

        }
	}
	

}